package com.quanhenghe;
import java.sql.*;

import com.quanhenghe.conf.GetSql;

public class Main {
    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";  
    static final String DB_URL = "jdbc:mysql://172.16.8.138:3306/db_info_grab_conf";
    
    static final String USER = "tafadmin";
    static final String PASS = "tafadmin2017";
    
    public static void main(String[] args) {
    	 Connection conn = null;
         Statement stmt = null;
         try{
             // 注册 JDBC 驱动
             Class.forName(JDBC_DRIVER);
         
             // 打开链接
             System.out.println("连接数据库...");
             conn = DriverManager.getConnection(DB_URL,USER,PASS);
         
             // 执行插入
             System.out.println(" Inserting...");
             stmt = conn.createStatement();
             	//获取sql
             
             GetSql gsql = new GetSql();
             String []sqls = gsql.getInsSql(); 
             
             for(int i=0;i<sqls.length;i++) {
            	 System.out.println(stmt.executeUpdate(sqls[i]));
             }
             
             //更新抓取时间
//             int timesp = 200,fid = 1850,jgid =30 ;
//   	      String updateSql="";
//   	      for(;fid<1930;fid+=jgid,timesp+=200) {
//   	    	  updateSql = String.format("UPDATE grab_source_conf " + 
//   	  	      		"SET grab_freq = %d ,update_time = NOW() " + 
//   	  	      		"WHERE station_id " + 
//   	  	      		"BETWEEN %d AND %d;", timesp,fid,fid+jgid);
//   	    	  System.out.println(updateSql);
//   	    	  System.out.println(stmt.executeUpdate(updateSql));
//   	      }
             
             
             //控制错误
             //保存 成功 和错误信息
             

             // 完成后关闭
             stmt.close();
             conn.close();
         }catch(SQLException se){
             // 处理 JDBC 错误
             se.printStackTrace();
         }catch(Exception e){
             // 处理 Class.forName 错误
             e.printStackTrace();
         }finally{
             // 关闭资源
             try{
                 if(stmt!=null) stmt.close();
             }catch(SQLException se2){
             }// 什么都不做
             try{
                 if(conn!=null) conn.close();
             }catch(SQLException se){
                 se.printStackTrace();
             }
         }
         System.out.println("Finish!");
     }
	}

